package com.qf.work;

import com.qf.util.ConnUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import org.junit.Test;

import java.io.IOException;

/**
 * work queue模式
 */
public class Publisher {

    @Test
    public void publish() throws Exception {
        //1. 获取connection对象
        Connection connection = ConnUtil.getConnection();

        //2. 创建Channel对象
        Channel channel = connection.createChannel();

        //3. 创建队列（队列名称，是否持久化，是否排外，自动删除，其他参数）
        channel.queueDeclare("work-queue",true,false,false,null);

        //4. 发送消息（交换机为""，Routingkey编写的是队列名，消息的其他参数，byte[]类型消息）
        String s = "Work Queue";
        for (int i = 0; i < 10; i++) {
            String msg = s + i;
            channel.basicPublish("","work-queue",null,msg.getBytes());
        }

        System.out.println("OK！");
    }


}
